package com.hzlh.mq;

import com.hzlh.configuration.RabbitConfig;
import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * @Description: Mq消息处理
 * @Author: linker_zhang
 * @Date: Created in 2020/6/2 14:01
 * @Version:1.0.0
 */
//@Component
@Slf4j
public class MqReceiver {

//    @Async
//    @RabbitListener(queues = RabbitConfig.QUEUE_A)
//    public void directParse(String msg) {
//        try {
//            LOGGER.debug("从mq接收待解析文件列表数据：" + msg);
//           //TODO 业务处理
//        } catch (Exception e) {
//            LOGGER.warn("mq数据错误" + e.getMessage());
//            e.printStackTrace();
//        }
//    }
}
